2bec59ec3e221e4154671370421f77a5a406cbd5,src/main/java/org/elasticsearch/action/bulk/BulkProcessor.java,BulkProcessor,awaitClose,#number#TimeUnit#,218

Before Change


        if (this.concurrentRequests < 1) {
            return true;
        }
        return semaphore.tryAcquire(this.concurrentRequests, timeout, unit);
    }

    /**

After Change


        if (this.concurrentRequests < 1) {
            return true;
        }
        if (semaphore.tryAcquire(this.concurrentRequests, timeout, unit)) {
            semaphore.release(this.concurrentRequests);
            return true;
        }
        return false;